package org.xxd.kafka.clients.producer;

import java.io.Closeable;

/**
 * @author: XiaoDong.Xie
 * @create: 2020-09-27 10:05
 * @description: The interfaces for the {@link KafkaProducer}
 */
public interface Producer<K, V> extends Closeable {

    void send(ProducerRecord<K, V> record);

    void send(ProducerRecord<K, V> record, Callback callback);

    @Override
    void close();
}
